package com.ruoyi.generator.callback;

import com.ruoyi.generator.domain.MqttProperty;
import com.ruoyi.generator.util.MQTTClient;
import lombok.Getter;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttMessage;

public abstract class MqttCallbackObserver {
    private MQTTClient mqttClient;

    public void connectComplete(boolean reconnect, String serverURI) {

    }

    public void connectionLost(Throwable cause) {

    }

    public void messageArrived(String topic, MqttMessage message) throws Exception {

    }

    public void deliveryComplete(IMqttDeliveryToken token) {

    }

    public MQTTClient getMqttClient() {
        return mqttClient;
    }

    public void setMqttClient(MQTTClient mqttClient) {
        this.mqttClient = mqttClient;
    }


}
